package dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import conexion.BBDD;
import dao.interfaces.ISorteoDAO;
import dao.interfaces.IVpoDAO;
import dto.SorteoDTO;

public class SorteoDAO implements ISorteoDAO{
		
		public SorteoDTO obtenerSorteoByVpo(int idVpo) throws SQLException{
			SorteoDTO sorteoDto = new SorteoDTO();
			Connection c = BBDD.abrirConexion();
			String sql = "SELECT * FROM sorteo WHERE vpo="+idVpo+";";
			PreparedStatement pr = c.prepareStatement(sql);
			ResultSet rs = pr.executeQuery();
			if(rs.next()){
				sorteoDto.setFecha((rs.getDate("fecha")));
				sorteoDto.setNumViviendas(rs.getInt("numero_viviendas"));
				sorteoDto.setPid(rs.getInt("pid"));
				IVpoDAO vpoDao = new VpoDAO();
				sorteoDto.setVpo(vpoDao.obtenerVpo(idVpo));
			}
			BBDD.cerrarConexion(c);
			return sorteoDto;
		}
		
		public SorteoDTO obtenerSorteoById(int id) throws SQLException{
			SorteoDTO sorteoDto  = new SorteoDTO();
			Connection c = BBDD.abrirConexion();
			String sql = "SELECT * FROM sorteo WHERE id="+id+";";
			PreparedStatement pr = c.prepareStatement(sql);
			ResultSet rs = pr.executeQuery();
			if(rs.next()){
				sorteoDto.setFecha((rs.getDate("fecha")));
				sorteoDto.setNumViviendas(rs.getInt("numero_viviendas"));
				sorteoDto.setPid(rs.getInt("pid"));
				IVpoDAO vpoDao = new VpoDAO();
				sorteoDto.setVpo(vpoDao.obtenerVpo(rs.getInt("vpo")));
			}
			BBDD.cerrarConexion(c);
			return sorteoDto;
		}
}
